package com.example.session;

import io.netty.channel.Channel;
import lombok.Data;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import io.netty.util.AttributeKey;

@Data
public class MqttSession {
    private String clientId;
    private Channel channel;
    private Set<String> subscriptions = ConcurrentHashMap.newKeySet();
    private boolean cleanSession;
    private long lastActiveTime;
    public static final AttributeKey<String> CLIENT_ID = AttributeKey.valueOf("clientId");
} 